package org.example.ch4;

import io.reactivex.rxjava3.core.Observable;

import java.util.ArrayList;

public class Main3 {

    public static void main(String[] args) {
        ArrayList<Integer> list = new ArrayList<Integer>();
        for (int i = 0; i < 1000; i++) {
            list.add(i);
        }

        Observable.fromIterable(list)
                .filter(item -> item % 3 == 0)
                .count() // count生成新的响应式流，该响应式流中只有一个元素就是上个流的元素个数
                .subscribe(
                        System.out::println
                );
    }
}
